package com.atguigu.app;

import com.atguigu.utils.MyKafkaUtil;
import com.atguigu.utils.MysqlUtil;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;

/**
 * @className: Test5_MysqlUtil
 * @author: LinCong
 * @description:
 * @date: 2023/1/31 22:19
 * @version: 1.0
 */
public class Test5_MysqlUtil {
    public static void main(String[] args) {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        env.setParallelism(1);
        StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);

//        tableEnv.executeSql(MysqlUtil.getBaseDicLookUpDDL()).print();

        tableEnv.executeSql(MyKafkaUtil.getTopicDb("aaa")).print();
    }
}
